package io.gitee.skyarthur1987.leporidae.delayqueue.api;

import io.gitee.skyarthur1987.leporidae.delayqueue.core.DelayQueuePollEvent;

import java.util.Set;

/**
 * <p>延迟队列轮询事件处理器</p>
 * <p>一个处理器支持多个主题队列的处理</p>
 * Created by skyarthur on 2023/1/28
 */
public interface DelayQueuePollEventHandler {

    /**
     * 事件处理
     *
     * @param pollEvent 轮询事件
     */
    void handle(DelayQueuePollEvent pollEvent);

    /**
     * 支持处理的延迟队列主题集合
     *
     * @return 主题集合
     */
    Set<String> getSupportedTopics();
}
